package com.sam.kafka.consumer;

import org.apache.kafka.clients.consumer.ConsumerConfig;

import java.util.HashMap;
import java.util.Map;

/**
 * @author: wm.xue
 * @date: 2021/11/10 9:52
 * @description: 防止误判 设置重平衡参数
 */
public class _05_Consumer_Rebalance {
    public static void main(String[] args) {
        Map<String, Object> configs = new HashMap<>();

        // 心跳超时间
        configs.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 6000);

        // 发送心跳的时间间隔
        configs.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 2000);

        // 拉取的时间间隔，超过拉取时间间隔，消费组将消费者进行剔除
        configs.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "最大业务的消费时间再加1分钟");

    }
}
